package com.example.model;

import lombok.Data;
import java.util.List;
import java.util.Map;

@Data
public class CanalMessage {
    // 数据库名称
    private String database;
    // 表名
    private String table;
    // 操作类型: INSERT, UPDATE, DELETE
    private String type;
    // 执行时间
    private Long es;
    // 数据变更时间
    private Long ts;
    // SQL语句
    private String sql;
    // 变更前数据
    private List<Map<String, Object>> old;
    // 变更后数据
    private List<Map<String, Object>> data;
    // DDL的SQL语句
    private String sqlType;
    // 主键字段名
    private List<String> pkNames;
} 